package com.gandong8.trace.tool.config.kafka.properties;

import lombok.Data;

@Data
public class KafkaConsumerCommonData {
    private String servers;
    private String groupId;
    private String clientId="trace_log";
    private Boolean autoCommit = false;
    private String offsetReset = "earliest";
    private String sessionTimeout = "15000";
    private String autoCommitInterval = "100";
    private String topics;
    private String beanName;
    private String ackMode = "";
    private String keyDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";
    private String valueDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";
}
